# -*- coding: utf-8 -*-
from airflow.operators.python import PythonOperator
from .taking_sign_to_oss import main
from jms.doris.jms_dwd.dwd_waybill_prescription_reach_details import \
    doris_jms_dwd__dwd_waybill_prescription_reach_details

taking_sign_to_oss = PythonOperator(
    task_id='taking_sign_to_oss',
    email=['hejian@yl-scm.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    python_callable=main,
)

taking_sign_to_oss << [doris_jms_dwd__dwd_waybill_prescription_reach_details]
